/*package com.xzh.seckill.config;


import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQDirectConfig {
    public static final String queue01 = "queue_direct01";
    public static final String queue02 = "queue_direct02";
    public static final String exchange = "exchangedirect";
    public static final String ROUTINGNAME1 = "queue.red";
    public static final String ROUTINGNAME2 = "queue.blue";
    @Bean
    public Queue queue01()
    {
        return new Queue(queue01);
    }
    @Bean
    public Queue queue02()
    {
        return new Queue(queue02);
    }
    @Bean
    public DirectExchange directExchange()
    {
        return new DirectExchange(exchange);
    }
    @Bean
    public Binding binding01()
    {
        return BindingBuilder.bind(new Queue(queue01)).to(new DirectExchange(exchange)).with(ROUTINGNAME1);
    }

    @Bean
    public Binding binding02()
    {
        return BindingBuilder.bind(new Queue(queue02)).to(new DirectExchange(exchange)).with(ROUTINGNAME2);
    }

}*/
